package com.hugang.io.bufferedstream;

import org.junit.Test;

import java.io.*;

/**
 * 处理流之一：缓冲流的使用
 *
 * 1.缓冲流：
 * BufferedInputStream
 * BufferedOutputStream
 * BufferedReader
 * BufferedWriter
 *
 * 2.作用：提供流的读取、写入的速度
 *   提高读写速度的原因：内部提供了一个缓冲区
 *
 * 3. 处理流，就是“套接”在已有的流的基础上。
 *
 * @author hg
 * @date 2020/6/21 14:42
 */
public class BufferedStreamTest {

    public static void main(String[] args) {
        long start = System.currentTimeMillis();

        String src = "D:\\BaiduYunDownload\\尚硅谷宋红康Java核心基础_好评如潮\\课件笔记源码资料\\3_软件.zip";
        String dest = "D:\\temp\\3_软件.zip";
        copyFile(src, dest);
        long end = System.currentTimeMillis();
        System.out.println("花费：" + (end - start) + "毫秒");
    }

    public static void copyFile(String srcPath, String descPath){
        FileInputStream fis = null;
        FileOutputStream fow = null;
        BufferedInputStream bis = null;
        BufferedOutputStream bos = null;
        try {
            //1、创建File类的对象，指明读入和写出文件
            File srcFile = new File(srcPath);
            File destFile = new File(descPath);

            //2、造流
            //2.1 造节点流
            fis = new FileInputStream(srcFile);
            fow = new FileOutputStream(destFile);
            //2.2 造缓冲流
            bis = new BufferedInputStream(fis);
            bos = new BufferedOutputStream(fow);

            //3、读入和写出数据
            byte[] b = new byte[1024];
            int len;
            while ((len = bis.read(b)) != -1) {
                bos.write(b, 0, len);
            }
            System.out.println("复制成功");
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            //4、流的关闭
            //要求：先关闭外层流，再关闭内层流
            //说明：关闭外层流的同时，内层流也会自动关闭
            try {
                if (bos != null)
                    bos.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
            try {
                if (bis != null)
                    bis.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

    /*
    使用BufferedReader和BufferedWriter实现文本文件的复制

     */
    @Test
    public void testBufferedReaderBufferedWriter(){
        BufferedReader br = null;
        BufferedWriter bw = null;
        try {
            //创建文件和相应的流
            br = new BufferedReader(new FileReader(new File("dbcp.txt")));
            bw = new BufferedWriter(new FileWriter(new File("dbcp1.txt")));

            //读写操作
            //方式一：使用char[]数组
//            char[] cbuf = new char[1024];
//            int len;
//            while((len = br.read(cbuf)) != -1){
//                bw.write(cbuf,0,len);
//    //            bw.flush();
//            }

            //方式二：使用String
            String data;
            while((data = br.readLine()) != null){
                //方法一：
//                bw.write(data + "\n");//data中不包含换行符
                //方法二：
                bw.write(data);//data中不包含换行符
                bw.newLine();//提供换行的操作

            }


        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            //关闭资源
            if(bw != null){

                try {
                    bw.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
            if(br != null){
                try {
                    br.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }

            }
        }

    }
}
